package com.apex.spark.batch;

import com.apex.spark.SparkBaseSink;
import com.apex.spark.SparkEnvironment;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;

/**
 * 对上游数据进行入库操作
 */
public interface SparkBatchSink  extends SparkBaseSink {
    /**
     * 处理上游数据并写入数据库
     * @param env 上下文执行环境
     * @param inDataSet 上游发送结果集
     */
    void outputBatch(SparkEnvironment env, Dataset<Row> inDataSet);
}
